// npm install mysql 安装mysql
const mysql = require('mysql') // 引入mysql

function queryDB(sql, callback) {
	// 创建一个数据库连接对象
	const connection = mysql.createConnection({
		host: 'localhost',
		user: 'root',
		password: 'b123',
		database: 'goodsmanager_db',
	})

	// 创建连接
	connection.connect()

	//执行sql
	connection.query(sql, function (err, results) {
		if (err) {
			console.log('操作数据库出错 ', err)
			return
		}
		console.log(results)
		callback(results)
	})

	connection.end() // 结束连接
}

/**
 * promise封装异步数据库操作
 * @param {*} sql 
 * @returns 
 */
function queryDBPromise(sql) {
	return new Promise((resolve, reject) => {
		// 创建一个数据库连接对象
		const connection = mysql.createConnection({
			host: 'localhost',
			user: 'root',
			password: 'b123',
			database: 'goodsmanager_db',
		})

		// 创建连接
		connection.connect()

		//执行sql
		connection.query(sql, function (err, results) {
			if (err) {
				reject(err)
				return
			}
			resolve(results)
		})

		connection.end() // 结束连接
	})
}

module.exports = {
	queryDBPromise,
    queryDB
}
